package threadcoreknowledge.stopthreads.scy1;

import java.util.concurrent.ArrayBlockingQueue;

public class TestArrayBlockingQueue {
    public static void main(String[] args) throws InterruptedException {

        // 对于blockingQueue , 当满了的时候,继续add,程序抛出一个运行时异常,程序中断
        // 当满了的时候,继续put时,程序一直卡在那里不动了
        ArrayBlockingQueue<Integer> queue = new ArrayBlockingQueue<>(3);

        queue.add(22);
        System.out.println(queue.size());
        System.out.println(queue.element());
        queue.add(2);
        queue.add(3); //
        System.out.println("------第1次");
        queue.put(4);
        System.out.println("------第2次");


        queue.add(5);
    }
}
